package com.example.redis.jedisCluster;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;

import java.util.HashSet;
import java.util.Set;

@Configuration
public class RedisHostsConfig {

    @Value("${spring.redis.host}")
    private String hosts;

    /**
     * 获取jedis链接
     *
     * @return
     */
//    @Bean
//    public JedisCluster redisCluster() {
//        try {
//            Set<HostAndPort> nodes = new HashSet<>();
//            String[] hostArray = hosts.split(",");
//            for (String host : hostArray) {
//                String[] ipAndPort = host.split(":");
//                nodes.add(new HostAndPort(ipAndPort[0], Integer.parseInt(ipAndPort[1])));
//            }
//            JedisCluster cluster = new JedisCluster(nodes);
//            return cluster;
//        } catch (Exception e) {
//            e.printStackTrace();
//            return null;
//        }
//    }
}

